package mqConsumer

import (
	"fmt"
	"github.com/IBM/sarama"
)

func HandlerRecordOnReceive(message *sarama.ConsumerMessage) {

	fmt.Println(message.Topic, "+", message.Value)

}

func HandlerRecordOnError() {

}

func HandlerDigOnReceive(message *sarama.ConsumerMessage) {
	fmt.Println(message.Topic, "+", message.Value)

}

func HandlerDigOnError() {

}
